package com.didi.gulimall.ware.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.didi.gulimall.common.entity.LocalMqEntity;
import com.didi.gulimall.ware.dao.LocalMqDao;
import com.didi.gulimall.ware.service.LocalMqService;
import org.springframework.stereotype.Service;


/**
 * @author 10626
 */
@Service("localMqService")
public class LocalMqServiceImpl extends ServiceImpl<LocalMqDao, LocalMqEntity> implements LocalMqService {


    @Override
    public void updateMqStatus(String messageId, Integer consumed) {
        baseMapper.updateMqStatus(messageId,consumed);
    }

    @Override
    public void updateMqStatusReg(String messageId, Integer retries) {
        baseMapper.updateMqStatusReg(messageId,retries);
    }
}